package com.kancy.streamplus.channel;

import org.springframework.messaging.Message;

/**
 * <p>
 * PollingMessageExceptionHander
 * <p>
 *
 * @author: kancy
 * @date: 2020/3/23 10:37
 **/

public interface PollingMessageExceptionHandler {
    /**
     * 处理异常
     * @param message
     * @param e
     */
    void onException(Message<?> message, Exception e);
}
